package delivery

import "learning/gooop/saga/mqs/models"

type iMsgSource interface {
	MsgChan() <- chan *models.QueuedMsg
}

type tSourceExpireFunc func() bool